home *** CD-ROM | disk | FTP | other *** search
/ Aminet 19 / Aminet 19 (1997)(GTI - Schatztruhe)[!][Jun 1997].iso / Aminet / comm / net / ARemote1_00B.lha / ARemote / source / divert.timer.c < prev    next >
C/C++ Source or Header  |  1997-04-27  |  8KB  |  284 lines
  1.  
  2. #include <devices/timer.h>
  3.  
  4. #include <exec/libraries.h>
  5. #include <exec/memory.h>
  6. #include <libraries/commodities.h>
  7. #include <dos/dos.h>
  8. #include <clib/exec_protos.h>
  9. #include <clib/alib_protos.h>
  10. #include <clib/alib_stdio_protos.h>
  11. #include <clib/commodities_protos.h>
  12. #include <devices/inputevent.h>
  13. #include <clib/AMarquee_protos.h>
  14. #include <pragmas/AMarquee_pragmas.h>
  15.  
  16. int main(int, char **);
  17. void ProcessMsg(CxObj * broker, struct MsgPort * broker_mp, CxObj * cocustom);
  18. void CxFunction(CxMsg *, CxObj *);
  19.  
  20. struct Library * AMarqueeBase = NULL;
  21. struct QSession * session     = NULL;
  22. struct Library * CxBase, *IconBase, * TimerBase;
  23. int port = 20000;
  24. BOOL BConnectOkay = FALSE;
  25. struct timerequest * TimerIO;
  26. struct MsgPort * event_mp;
  27.  
  28. char * connectTo = "";  /* IP name to connect to, or "" if we should go passive instead */
  29. char * hosts = "";
  30.  
  31. struct NewBroker newbroker =
  32. { 
  33.   NB_VERSION,
  34.   "Divert",
  35.   "Divert",
  36.   "show divert",
  37.   NBU_UNIQUE | NBU_NOTIFY,
  38.   0, 0, 0, 0
  39. };
  40.  
  41. /* Makes pcString lower case */
  42. char * ToLower(char * pcString)
  43. {
  44.     char * pcTemp = pcString;
  45.     
  46.     while(*pcTemp) 
  47.     {
  48.         if ((*pcTemp >= 'A')&&(*pcTemp <= 'Z'))
  49.             *pcTemp += 'a'-'A';
  50.         pcTemp++;
  51.     }
  52.     return(pcString);
  53. }
  54.  
  55. void edebug(int i)
  56. {
  57.   int a = *((int *)i);
  58. }
  59.  
  60. /* return TRUE iff the string represents the boolean value true */
  61. BOOL ParseBool(char * string)
  62. {
  63.   char temp[100];
  64.   
  65.   strncpy(temp,string,sizeof(temp));
  66.   temp[99]=0;
  67.   
  68.   ToLower(temp);
  69.   
  70.   return(
  71.     (*temp=='\0')              ||  /* then it's just KEYWORD, so yes, right? */
  72.     (strcmp("true",temp) == 0) ||
  73.     (strcmp("yes",temp)  == 0) ||
  74.     (strcmp("1",temp)    == 0));   /* Anyone who specifies 1 for true is a weenie! */
  75. }
  76.  
  77.  
  78. int main(int argc, char ** argv)
  79. {
  80.   UBYTE ** ttypes;
  81.   CxMsg * msg;
  82.   
  83.   if (NULL == (TimerIO = (struct timerequest *)AllocMem(sizeof(struct timerequest), MEMF_PUBLIC | MEMF_CLEAR)))
  84.   {
  85.     printf("Couldn't allocate timerequest\n");
  86.     exit(10);
  87.   }
  88.   if (OpenDevice(TIMERNAME, UNIT_MICROHZ, TimerIO, 0))
  89.   {
  90.     printf("Couldn't open timer.device\n");
  91.     FreeMem(TimerIO, sizeof(struct timerequest));
  92.     exit(10);
  93.   }
  94.   TimerBase = (struct Library *) TimerIO->tr_node.io_Device;
  95.   
  96.   if (AMarqueeBase = OpenLibrary("amarquee.library",42L))
  97.   {
  98.     if (CxBase = OpenLibrary("commodities.library", 37L))
  99.     {
  100.       if (IconBase = OpenLibrary("icon.library", 36L))
  101.       {
  102.         struct MsgPort * broker_mp;
  103.         CxObj * broker, * cocustom;
  104.  
  105.         if (event_mp = CreateMsgPort())
  106.         {
  107.           if (broker_mp = CreateMsgPort())
  108.           { 
  109.             newbroker.nb_Port = broker_mp;
  110.         
  111.             ttypes = ArgArrayInit(argc, argv);
  112.             newbroker.nb_Pri = (BYTE) ArgInt(ttypes, "CX_PRIORITY", 0);
  113.         
  114.             connectTo = ArgString(ttypes, "CONNECT", "");
  115.             hosts     = ArgString(ttypes, "ACCEPT",  "");
  116.             port      = ArgInt(ttypes,    "PORT", port);
  117.             
  118.             if (broker = CxBroker(&newbroker, NULL))
  119.             {
  120.               if (cocustom = CxCustom(CxFunction, 0L))
  121.               {
  122.                 AttachCxObj(broker, cocustom);
  123.                 ActivateCxObj(broker, 1L);
  124.                 ProcessMsg(broker, broker_mp, cocustom);
  125.               }
  126.               DeleteCxObjAll(broker);          
  127.               while(msg = (CxMsg *) GetMsg(broker_mp)) ReplyMsg((struct Message *)msg);  
  128.             }
  129.             DeletePort(broker_mp);
  130.           }
  131.         
  132.           while(msg = (CxMsg *) GetMsg(event_mp)) FreeMem(msg, ((struct Message *)msg)->mn_Length);
  133.           DeletePort(event_mp);
  134.         }
  135.       
  136.         ArgArrayDone();
  137.         CloseLibrary(IconBase);
  138.       }
  139.       CloseLibrary(CxBase);
  140.     }
  141.     CloseLibrary(AMarqueeBase);
  142.   }
  143.   
  144.   /* free timer.device */
  145.   CloseDevice((struct IORequest *)TimerIO);
  146.   FreeMem(TimerIO, sizeof(struct timerequest));
  147.   return(0);
  148. }
  149.  
  150. void Disconnect()
  151. {
  152.   if (session) QFreeSession(session);
  153.   session = NULL;
  154.   BConnectOkay = FALSE;
  155. }
  156.  
  157. void Reconnect()
  158. {
  159.   LONG pPort = port;
  160.   
  161.   Disconnect();
  162.   
  163.   if (*connectTo) printf("Connecting to [%s]\n",connectTo);
  164.              else printf("Accepting connections from [%s]\n",hosts);
  165.              
  166.   if (*connectTo) session = QNewSessionAsync(connectTo, pPort, "ARemote");
  167.              else session = QNewHostSession(hosts, &pPort, "ARemote");
  168. }
  169.  
  170. void ProcessMsg(CxObj * broker, struct MsgPort * broker_mp, CxObj * cocustom)
  171. {
  172.   struct Message * msg;
  173.   CxMsg * cmsg;
  174.   ULONG sigrcvd, msgid;
  175.   BOOL keepGoing = TRUE;
  176.  
  177.   Reconnect();  /* attempt an initial connection */
  178.      
  179.   while(keepGoing)
  180.   {
  181.     sigrcvd = Wait(SIGBREAKF_CTRL_C | (1L<<broker_mp->mp_SigBit) | (1L<<event_mp->mp_SigBit) | (session ? (1L<<session->qMsgPort->mp_SigBit) : 0L));
  182.     
  183.     while(cmsg = (CxMsg *)GetMsg(broker_mp))
  184.     {
  185.       msgid = CxMsgID(cmsg);
  186.       ReplyMsg((struct Message *)cmsg);
  187.       
  188.       switch(msgid)
  189.       {
  190.         case CXCMD_DISABLE: printf("disabled.\n"); ActivateCxObj(broker, 0L); break;
  191.         case CXCMD_ENABLE:  printf("enabled.\n");  ActivateCxObj(broker, 1L); break;
  192.         case CXCMD_KILL:    printf("kill.\n");     keepGoing = FALSE;         break;
  193.         case CXCMD_UNIQUE:  printf("uniqued.\n");  keepGoing = FALSE;         break;
  194.       }
  195.     }
  196.  
  197.     /* handle incoming InputEvent messages from our custom CxObject */
  198.     {
  199.       BOOL BSent = FALSE;
  200.  
  201.       while(msg = (struct Message *)GetMsg(event_mp))
  202.       {
  203.         if ((session)&&(BConnectOkay))
  204.         {
  205.           struct InputEvent * ie = (struct InputEvent *) (((UBYTE *)msg)+sizeof(struct Message));
  206.       
  207.           /* Send a copy of the Input Event to our buddy */
  208.           (void)QStreamOp(session, "e", ie, sizeof(struct InputEvent));
  209.           BSent = TRUE;
  210.         }
  211.         FreeMem(msg, msg->mn_Length);
  212.       }
  213.       if (BSent) QGo(session, 0L);
  214.     }
  215.  
  216.     if (session)
  217.     {
  218.       struct QMessage * qmsg;
  219.       
  220.       while(qmsg = (struct QMessage *)GetMsg(session->qMsgPort))
  221.       { 
  222.         if (qmsg->qm_Status == QERROR_NO_ERROR)
  223.         {
  224.           if (qmsg->qm_ID == 0) 
  225.           {
  226.             printf("Connection to %s established.\n",qmsg->qm_Path);
  227.             BConnectOkay = TRUE;
  228.           }
  229.           else
  230.           {
  231.             if (qmsg->qm_DataLen == sizeof(struct InputEvent))
  232.             { 
  233.               struct InputEvent * ie = (struct InputEvent *)qmsg->qm_Data;
  234. /*              GetSysTime(&(ie->ie_TimeStamp));  */
  235.               AddIEvents(ie);
  236.             }
  237.             else printf("Error, bad data size (%i != %i)\n",qmsg->qm_DataLen, sizeof(struct InputEvent));
  238.           }
  239.         }
  240.         else
  241.         {
  242.           printf("Error %i received, disconnecting\n", qmsg->qm_Status);
  243.           FreeQMessage(session, qmsg);  /* Gotta free this NOW!  Before the session is gone */
  244.           Disconnect();
  245.           break;  /* Can't evaluate while() condition again!  session is dangling! */
  246.         }
  247.         FreeQMessage(session, qmsg);
  248.       }
  249.     }
  250.     
  251.     if (sigrcvd & SIGBREAKF_CTRL_C) {printf("CTRL-C detected.\n"); keepGoing = FALSE;}
  252.   }
  253.   
  254.   if (session) 
  255.   {
  256.     QFreeSession(session);
  257.     session = NULL;
  258.   }
  259. }
  260.  
  261. __geta4 void CxFunction(register CxMsg * cxm, CxObj * co)
  262. {
  263.   struct InputEvent * ie;
  264.   
  265.   ie = (struct InputEvent *)CxMsgData(cxm);
  266.  
  267.   if ((ie->ie_Class == IECLASS_RAWKEY)     ||
  268.       (ie->ie_Class == IECLASS_RAWMOUSE)   ||
  269.       (ie->ie_Class == IECLASS_POINTERPOS)) 
  270.   {
  271.      /* Send a message containing a copy of this InputEvent to our program for transmission */
  272.      int bufLen = sizeof(struct Message)+sizeof(struct InputEvent);
  273.      struct Message * msg = (struct Message *)AllocMem(bufLen, MEMF_PUBLIC | MEMF_CLEAR);
  274.        
  275.      if (msg)
  276.      {
  277.        msg->mn_Node.ln_Type = NT_MESSAGE;
  278.        msg->mn_Length       = bufLen;
  279.        msg->mn_ReplyPort    = NULL;   /* No reply needed; we'll just free it */
  280.        memcpy(((UBYTE *)msg)+sizeof(struct Message), ie, sizeof(struct InputEvent));
  281.        PutMsg(event_mp, msg);
  282.      } 
  283.   }
  284. }